package com.asiainfo.dacp.datastash.worker.executor;

import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.DataxWorkerExecutor;

/**
 * Worker的执行器类
 *
 * worker完成任务的接收，并解析成相应的执行引擎，完成执行
 *
 * 1）本次使用fork进程的方式执行，datax，kafka-connector，dp，后续需要改成在本进程里面执行的wrapper实现
 *
 * @author MeiKefu
 * @date 2017-10-31
 */
public class WorkerExecutor {

    public void execute(){
        new DataxWorkerExecutor().execute();
    }

    public static void main(String[] args){

    }
}
